package com.health.listener;

import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * work工作队列模式:
 * 一个生产者发送消息到消息队列,多个消费者等待这个消息队列,只有一个消费者能等到,发送多个消息使用轮询模式
 */
@Component
public class Listener2 {
    /**
     * 1号消费者
     */
    @RabbitListener(queuesToDeclare = @Queue("message.queue3"))
    public void listener1(String message){
        System.out.println("1号>>接受到的消息:"+message);
    }
    /**
     * 2号消费者
     */
    @RabbitListener(queuesToDeclare = @Queue("message.queue3"))
    public void listener2(String message){
        System.out.println("2号消费者+++接受到的消息:"+message);
    }
}
